
package com.changdu.seatunnel.admin.entity;

import com.baomidou.mybatisplus.annotation.TableName;

import lombok.Data;

@Data
@TableName("data_kafka_template")
public class DataKafkaTemplate extends SyncTask {

    private String sourceDataCenter; // 源数据中心

    private String sourceInstance; // 源数据实例

    private String sourceDatabase; // 源库

    private String sourceTable; // 源表

    private String targetDataCenter; // 目标数据中心

    private String targetInstance; // 目标数据实例

    private String targetDatabase; // 目标库

    private String targetTable; // 目标表

    private String templateContent; // schema模板内容
    
    private String topic;
    
}
